package org.yonggan.shop.sql.report

import org.apache.spark.sql.DataFrame
import org.yonggan.shop.constant.ConfigurationManager
import org.yonggan.shop.utils.SparkUtils

/**
  * 成交总金额
  *
  */
object RptMoneySum {

  def main(args: Array[String]): Unit = {


    val spark = SparkUtils.getSparkSession("成交总金额")

    // 文件输出
    val jsonDF: DataFrame = spark.read.json(ConfigurationManager.TASK_INJSON)
    import org.apache.spark.sql.functions._

    jsonDF.filter(
      """
        |event_type = 4
      """.stripMargin).show()




  }

}
